//package com.heima.test;
//
//import org.apache.kafka.clients.producer.KafkaProducer;
//import org.apache.kafka.clients.producer.ProducerConfig;
//import org.apache.kafka.clients.producer.ProducerRecord;
//
//import java.util.Properties;
//
//public class ProducerStart {
//
//    private static final String TOPIC = "itcast-heima";
//
//    public static void main(String[] args) {
//
//        //添加kafka的配置信息
//        Properties properties = new Properties();
//        //配置broker信息
//        properties.put("bootstrap.servers","192.168.136.129:9092");
//        properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");
//        properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");
//        properties.put(ProducerConfig.RETRIES_CONFIG,10);
//
//        //生产者对象
//        KafkaProducer<String,String> producer = new KafkaProducer<String, String>(properties);
//
//        //封装消息
//        ProducerRecord<String,String> record = new ProducerRecord<String, String>(TOPIC,"00001","hello kafka!");
//        //发送消息
//        try {
//            producer.send(record);
//        }catch (Exception e){
//            e.printStackTrace();
//        }
//
//        //关系消息通道
//        producer.close();
//    }
//}
